import socketio

RABBITMQ = 'amqp://python:rabbitmqpwd@localhost:5672/toutiao'

mgr = socketio.KombuManager(RABBITMQ)

# 创建socketio对象
# async_mode 告知socketio 服务器使用eventlet协程服务器来托管运行
sio = socketio.Server(async_mode='eventlet', client_manager=mgr)
app = socketio.Middleware(sio)

